//package me.gavin.util
//
//import io.reactivex.processors.PublishProcessor
//
///**
// * 基于 RxJava2 的事件总线
// *
// * @author gavin.xiong 2018/9/11 0011
// */
//object RxBus {
//
//    // 有背压 无背压使用 PublishSubject.create<Any>().toSerialized()
//    val bus = PublishProcessor.create<Any>().toSerialized()
//
//    inline fun <reified T> toObservable() = bus.ofType(T::class.java)
//
//    fun post(e: Any) = bus.onNext(e)
//
//}